e3d3daa5fa6476004ab040f093a66c13910e1bf0,app-fabric/src/main/java/com/continuuity/internal/app/runtime/distributed/DistributedWorkflowProgramRunner.java,DistributedWorkflowProgramRunner,run,#Program#ProgramOptions#,42
Before Change
LOG.info("Launching distributed workflow: " + program.getName() + ":" + workflowSpec.getName());
String runtimeArgs = new Gson().toJson(options.getUserArguments());
// TODO (ENG-2526): deal with logging
WeavePreparer preparer
= weaveRunner.prepare(new WorkflowWeaveApplication(program, workflowSpec, hConfFile, cConfFile))
.addLogHandler(new PrinterLogHandler(new PrintWriter(System.out)))
.withArguments(workflowSpec.getName(),
String.format("--%s", RunnableOptions.JAR), program.getJarLocation().getName())
.withArguments(workflowSpec.getName(), String.format("--%s", RunnableOptions.RUNTIME_ARGS), runtimeArgs);
return new WorkflowWeaveProgramController(program.getName(), preparer.start()).startListen();
}
}
After Change
Preconditions.checkNotNull(workflowSpec, "Missing WorkflowSpecification for %s", program.getName());
LOG.info("Launching distributed workflow: " + program.getName() + ":" + workflowSpec.getName());
WeaveController controller = launcher.launch(new WorkflowWeaveApplication(program, workflowSpec,
hConfFile, cConfFile));
return new WorkflowWeaveProgramController(program.getName(), controller).startListen();
}
}